package com.runssnail.demo.kafka.jms;

import kafka.serializer.Decoder;


/**
 * Message Decoder
 *
 * Created by zhengwei on 2015/8/27.
 */
public class MessageDecoder implements Decoder<Object> {

    @Override
    public Object fromBytes(byte[] bytes) {
        return SerializeUtils.deserialize(bytes);
    }
}
